//package com.ruoyi.common.mq.rabbit.service;
//
//import com.ruoyi.common.mq.core.LogConsumer;
//import com.ruoyi.system.api.domain.SysOperLog;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.amqp.rabbit.annotation.RabbitListener;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.messaging.handler.annotation.Payload;
//import org.springframework.stereotype.Component;
//
//@Slf4j
//@Component
//@RabbitListener(queues = "log_queue")
//public class LogConsumerImpl extends LogConsumer {
//
//    @Autowired
//    private LogService logService;
//
//    @Override
//    public void handleLog(@Payload SysOperLog message) {
//        try {
//            log.info("日志信息：{}", message);
//            logService.saveSysLog(message);
//            log.info("日志入库成功：{}", message);
//        }catch (Exception e) {
//            log.error("日志入库失败", e);
//        }
//    }
//}